package com.dhcc.activemq.comsumer;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

/**
 * 
* <p>标题: P2PConsumer.java</p>
* <p>业务描述:健康管理平台</p>
* <p>公司:东华软件股份公司</p>
* <p>版权:dhcc2013</p>
* @author 胡凯
* @date 2019年7月29日
* @version V1.0
 */
@Component
public class P2PConsumer {
   
	// 使用JmsListener配置消费者监听的队列，其中name是接收到的消息
    @JmsListener(destination= "${my_queue}")
    // SendTo 会将此方法返回的数据, 写入到 OutQueue 中去.
    @SendTo("SQueue")
    public String receiver(String name) {
        System.out.println("消费者成功获取到生产者的消息，name="+name);
        return "消费者成功获取到生产者的消息，name=" + name;
    }
    
    
}